import requests

from config.config import config

wxpusher_config = config.get('notification', {}).get('wxpusher', {})


def send_message(content, summary):
    base_url = wxpusher_config.get('base_url')
    json_data = {
        "appToken": wxpusher_config.get('app_token'),
        "content": content,
        "summary": summary,
        "contentType": 2,
        "topicIds": wxpusher_config.get('topic_ids', []),
        # 是否验证订阅时间，true表示只推送给付费订阅用户，false表示推送的时候，不验证付费，不验证用户订阅到期时间，用户订阅过期了，也能收到。
        # 是否验证订阅时间，0：不验证，1: 只发送给付费的用户，2: 只发送给未订阅或者订阅过期的用户
        "verifyPayType": 0
    }
    # 发送 POST 请求
    response = requests.post(base_url, json=json_data)
    print(response.text)
